# -*- coding: utf-8 -*-
# @File  : schedule模块2.py
# @Author: zbh
# @Date  : 2025/2/19_14:04


import schedule
import time
import threading

def job(object):
    print("Hello,", object)

schedule.every(2).seconds.do(job,object="Python") # 每隔5秒执行一次job函数
schedule.every(5).seconds.do(job,object="Python_tag").tag("test") # 每隔5秒执行一次job函数，并添加标签test

def schedule_thread():
    while True:
        schedule.run_pending() # 运行所有可以运行的任务
        time.sleep(1)

# 启动条读取线程
thread1 = threading.Thread(target=schedule_thread)  # 创建线程
thread1.start()  # 启动线程
thread2 = threading.Thread(target=schedule_thread)  # 创建线程
thread2.start()  # 启动线程
# 打印线程的名称
print(thread1.name,thread2.name)


schedule.run_all() # 运行所有任务





# schedule.run_all(delay_seconds=5) # 延迟5秒运行所有任务


all_jobs = schedule.get_jobs() # 获取所有任务
print("所有任务：",all_jobs)
tag_jobs = schedule.get_jobs("test") # 获取标签为test的任务
print("有test标签的任务：",tag_jobs)


schedule.clear() # 清除所有任务

